package com.cpm.offcn.helloword;

import com.cpm.offcn.utils.RabbitUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Producer {
    public static void main(String[] args) throws IOException, TimeoutException {

        //获取tcp长连接
        Connection connection = RabbitUtils.getConnection();
        Channel channel = connection.createChannel();//创建通信通道（信道）

        //创建队列
        //queue是队列名
        //第二个参数表示是否持久化
        //第三个参数表示队列是否私有化，false表示所有消费者都可以访问，true表示只有第一次拥有他的消费者才能一直使用
        //第四个参数表示是否自动删除，false表示队列停掉后不自动删除这个队列
        //其他额外的参数，null
        channel.queueDeclare("QUEUE",false,false,false,null);

        String message = "hello rabbitmq";

        //exchange 交换机，暂时用不到所以为null
        //第二个参数为队列名称
        //第三个参数为额外的设置属性
        //最后一个参数是要传递的消息字节数组
        channel.basicPublish("","QUEUE",null,message.getBytes());
        channel.close();
        connection.close();
        System.out.println("发送成功");
    }
}
